package m1;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;


public class Producer {
    public static void main(String[] args) throws Exception {
        // 创建连接工厂,并设置设置连接信息
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.64.140");
        factory.setPort(5672);
        factory.setUsername("admin");
        factory.setPassword("admin");

        //建立连接
        Connection connection = factory.newConnection();
        //建立信道
        Channel channel = connection.createChannel();

        /*
          创建队列: (如果队列存在,不会重复创建)
            参数说明:
               1.队列名
               2.是否是持久队列
               3.是否是排他(独占)队列, false表示不排他
               4.是否自动删除(在没有消费者的情况下), false表示不自动删除
               5.其它参数属性
         */
        channel.queueDeclare("hello-world", false, false, false, null);


        /*
          发送消息
            参数说明:
               1.交换机, ""表示默认的交换机
               2.队列名
               3.消息的其它参数属性
               4.发送的消息
         */
        channel.basicPublish("", "hello-world",null, "Hello World!".getBytes());

        System.out.println("消息已经发送!");
        channel.close();

    }
}
